package com.mhuang.common.coder;

import com.mhuang.utils.TypeConvert;
import com.mhuang.vo.BaseRespMessage;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;

/**
 * 
 * @Package: com.mhuang.common.encoder
 * @Description 自定义编码器
 * @author huang.miao
 * @date 2017年1月16日 下午1:49:10  
 * @since 1.0.0
 * @group skiper-opensource
 */
@ChannelHandler.Sharable
public class ServerEncoder extends MessageToByteEncoder<BaseRespMessage>{

	
	@Override
	protected void encode(ChannelHandlerContext ctx, BaseRespMessage msg, ByteBuf out) throws Exception {
		
		//返回消息
		out.writeBytes(TypeConvert.LongToByteArray(msg.getMsgId(), 2));//版本号
		out.writeBytes(TypeConvert.LongToByteArray(msg.getResult(), 1));//消息ID
	}
}
